package com.github.hongkaiwen.rxjava.play.problem1.play;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

/**
 * 密级别：classify:p2#- User: hongkai Date: 04/08/2018 10:30 PM Description:
 */
public class BlockingSubscribePlay {

    public static void main(String... args){
        Observable.range(0, 100)
            .subscribeOn(Schedulers.computation())
            .blockingSubscribe(System.out::println);
//            .subscribe(System.out::println);
        System.out.println("finished.");
    }


}
